开发者接入

云边消息数据转发

启用路由实例后，系统将会向其目的地端点转发路由实例符合过滤器要求的数据。转发的最终数据为云边消息EVENT标准格式，且加密、压缩之后的数据。

EVENT数据格式

数据存储格式：

• JSON
• XML
• SERIALIZED(暂时等同JSON格式）
• CSV

event JSON格式

{
    "id": 1,
    "eventId": "f86797d2-9366-4b26-aa02-28a4a703bf10",
    "deviceId": "10000166",
    "productId": "100036",
    "protocol": 1,
    "data":{
        "temprature" : 30
    }
    "created": 1569664351174,
}

data对象为键值对对象，键为属性标志，值为属性数据值。例如"data":{"temprature" : 30}表示温度为30度。

event XML格式:

<Event>
    <ID></ID>
    <EventId>f86797d2-9366-4b26-aa02-28a4a703bf10</EventId>
    <DeviceId>10000166</DeviceId>
    <ProductId>100036</ProductId>
    <Protocol>1</Protocol>
    <Data>
        <temperature>
            30
        </temperature>
    </Data>
    <Created>1569664351174</Created>
</Event>

<Data></Data>节点中包含属性数据。子节点为属性标志，节点值为数据值。例如 <temprature>30</temprature>表示温度为30度。

event CSV格式:

ID,EventId,DeviceId,ProductId,Protocol,Data,Created
-----------------------------------------------------------
1,f86797d2-9366-4b26-aa02-28a4a703bf10,10000166,100036,1,cpu.used,0.015,1569664351174

Data对应的数据为“cpu.used，0.015”表示cpu.used属性值为0.015。

MySQL转发 EVENT 数据结构

MySQL形式数据转发与REST,MQTT,KAFKA其他类型不一致，数据结构以表形式存于数据库表中。结构如下：

其中data_string为属性键值对json格式，例如{ "temperature" : 30}

加密数据

加密方式暂时只支持AES-128加密,设置AES加密参数后，系统会对event数据进行相应参数加密后转发。

注：加密后的event数据会进行一次base64加密后再进行转发。开发者如需要对数据解密，首先需要将得到的数据依次进行base64解密和AES解密。

压缩数据

压缩数据方式暂只支持gzip和zip加密，选择相应压缩方式后，系统将对数据（加密后的数据）进行压缩后再进行转发。

自定义脚本

针对设备上传数据的自定义转发场景，目前支持Lua脚本。

脚本模板

--[[
 *  @param event 设备上传的数据table类型里面包含
 *  event["deviceid"] string  ——  设备ID
 *  event["pid"]   string  ——  产品ID
 *  event["protocol"] int  ——  协议类型
 *  event["eventId"] string  ——  设备数据上传event id
 *  event["ruleId"] string  ——  规则引擎转发id
 *  event["created"] string  ——  创建时间,可以被数据库datetime类型接受
 *  event["属性名"]  属性值类型  ——  属性值
 *  @return table类型res ={} 必须包含:
 *  res["data"],data里是需要发送的数据列表如res["data"] ={event1,event2}
 *  event1或者event2中必须包含device_id（设备ID）、name（属性名称）字段
 *  event中属性类型为Boolean时，0为false，1为true
--]]
function handler(event)
    event1 = {}
    event1["name"] = "someDouble"
    event1["device_id"] = event["deviceid"]
    event1["created"] = event["created"]
    event1["value"] = event["someDouble"]
    event2 = {}
    event2["name"] = "someInteger"
    event2["device_id"] = event["deviceid"]
    event2["created"] = event["created"]
    event2["value"] = event["someInteger"]
    res = {}
    res["data"]= {event1,event2}
    return res
end